import pymysql

# 2) 使用 PyMySQL 库建立与 MySQL 的连接，并返回一个 db 对象。connect( )方法中的"localhost" 参数为主机名 root"参数为连接 MySQL 的用户名 密码"参数为 MySQL 的连接
# 密码"test"参数表示操作的 MySQL 数据库。
db = pymysql.connect(host='localhost', user='root', password='root', port=3306, database='test')

# 3) 使用 connector 对象的 cursor( )方法建立对 MySQL 的操作游标。
cursor = db.cursor()

# 4) 使用游标 cursor 执行 SQL 语句。该 SQL 语句表示如果 test 数据库中存在 employee表，则先将其删除。这一步的目的就是防止出现重复数据。
cursor.execute("DROP TABLE IF EXISTS employee")

# 5) 使用字符串编写完成 SQL 语句。注意，这里使用三引号表示多行字符串。这里的SQL 语句使用 CREATE TABLE 创建一个名为 employee 的表，并设置 id、first_name.
# last_name、age、sex、income 的字段和属性，将 id 设为主键，字符集使用 utf8mb4。
sql = """
CREATE TABLE `employee` (
    `id` INT(11) NOT NULL AUTO_INCREMENT,
    `first_name` VARCHAR(20) NOT NULL,
    `last_name` VARCHAR(20) DEFAULT NULL,
    `age` INT(1) DEFAULT NULL,
    `sex` CHAR(1) DEFAULT NULL,
    `income` FLOAT DEFAULT NULL,
    PRIMARY KEY (`id`)
  ) ENGINE = INNODB DEFAULT CHARSET = utf8mb4;
"""

# 6） 执行前面的 SQL 语句。
cursor.execute(sql)

# 7) 打印输出提示字符串，并关闭连接。
print("Created table Successfull.")
db.close()

# 8) 输出结果如下。
# Created table Successful